#pragma  once
#include "../TdsReqHandler.h"
#include <map>
#include <mutex>

class TFPusher : public TdsCmdHandler
{
public:
    TFPusher():TdsCmdHandler(kPush){}
	void addPush(const std::string& key, const ReqInfo& req);
	void removePush(const std::string& key, const ReqInfo& req);
	void pushData(const std::string& key, const QString& data);

protected:
	std::multimap<std::string, ReqInfo>	m_registerPushes;
	std::mutex	m_mutex;
};
